package com.guchenbo.spark.sql

import org.apache.spark.sql.catalyst.parser.ParseException

import scala.collection.JavaConverters.setAsJavaSetConverter


/**
 * 用来把scala适配java
 *
 * @author guchenbo
 */
object JavaSparkSqlParser {

  /**
   * scala适配java的方法
   *
   * @param sqlText sql
   * @return
   */
  @throws(classOf[ParseException])
  def getFullTable(sqlText: String): java.util.Set[String] = {
    SparkSqlParser.getFullTable(sqlText).asJava
  }
}
